const http = require('http');
const fs = require('fs')

http
    .createServer((req, res) => {
        if (req.url == '/') {
            fs.createReadStream('./pic.html').pipe(res); //创建一个可读流 传输到res
        } else if (req.url == '/upload') { //当用户从这个地址进来时，上传文件时触发pic.html中的xhr
            let img = []
            let size = 0;
            req.on('data', chunk => { //数据传输，用img数组接受这些数据，size接受数据的长度
                img.push(chunk);
                size += chunk.length;
                console.log(chunk);
            })
            req.on('end', function () {
                const buffer = Buffer.concat(img, size) //缓冲二进制流
                fs.writeFileSync('small.jpg', buffer, (err) => {
                    if (err) {
                        return console.error(err);
                    }
                    console.log('文件上传成功');
                })
                res.end('文件上传成功')
            })
        }
    })
    .listen(1314)